package com.example.baselibs.net;


import io.reactivex.Observable;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;

/**
 * 创建一个观察者父类，将一些公共操作放到这里
 * 将一些重复操作的提出来，放到父类以免Loader里每个接口都有重复的代码。
 * 此处处理数据使用的时Rxjava订阅数据处理
 */
public abstract class RxObjectLoader {
    protected <T> Observable<T> observa(Observable<T> observable){
        return observable.subscribeOn(Schedulers.io()) //设定调度器
                .unsubscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread());//切换主线程
    }
}
